type go.pact.im/x/supervisor.managedProcess
9 uses
go.pact.im/x/supervisor (current package)
startstop.go#L47: m.processes.Range(func(pk K, _ *managedProcess[P]) bool {
supervisor.go#L24: processes typedMap[K, *managedProcess[P]]
supervisor.go#L46: type managedProcess[P process.Runner] struct {
supervisor.go#L127: func (m *Supervisor[K, P]) startProcessForKey(ctx context.Context, pk K) (*managedProcess[P], error) {
supervisor.go#L148: func (m *Supervisor[K, P]) startProcess(ctx context.Context, pk K, r P) (*managedProcess[P], error) {
supervisor.go#L163: func (m *Supervisor[K, P]) startProcessUnlocked(ctx context.Context, pk K, r P) (*managedProcess[P], error) {
supervisor.go#L164: p := &managedProcess[P]{
supervisor.go#L180: func (m *Supervisor[K, P]) watchdog(pk K, p *managedProcess[P]) {
supervisor.go#L215: m.processes.Range(func(pk K, _ *managedProcess[P]) bool {